package com.shanks.framework.mq.rocketmq.producer;

import com.shanks.framework.mq.common.constant.MQConstant;

/**
 * rocketmq 生产者属性
 */
public class RocketMQProducerAttribute {
    /**
     * 基础泳道namesrv
     */
    private String namesrvAddr;

    /**
     * 灰度泳道namesrv
     */
    private String canaryNamesrvAddr;

    /**
     * 实例名
     */
    private String instanceName;

    /**
     * 生产者key(会存在多个不同生产者，通过key去map中获取)
     */
    private String producerKey;

    /**
     * 消费者组
     */
    private String groupName;

    /**
     * 最大消息大小
     */
    private int maxMessageSize;

    /**
     * 消息发送超时
     */
    private int sendMsgTimeout;

    /**
     * 消息ack主题
     */
    private String ackMsgTopic = MQConstant.TOPIC.ACK_MSG_TOPIC;

    public String getNamesrvAddr() {
        return namesrvAddr;
    }

    public void setNamesrvAddr(String namesrvAddr) {
        this.namesrvAddr = namesrvAddr;
    }

    public String getCanaryNamesrvAddr() {
        return canaryNamesrvAddr;
    }

    public void setCanaryNamesrvAddr(String canaryNamesrvAddr) {
        this.canaryNamesrvAddr = canaryNamesrvAddr;
    }

    public String getInstanceName() {
        return instanceName;
    }

    public void setInstanceName(String instanceName) {
        this.instanceName = instanceName;
    }

    public String getProducerKey() {
        return producerKey;
    }

    public void setProducerKey(String producerKey) {
        this.producerKey = producerKey;
    }

    public String getGroupName() {
        return groupName;
    }

    public void setGroupName(String consumeGroup) {
        this.groupName = consumeGroup;
    }

    public int getMaxMessageSize() {
        return maxMessageSize;
    }

    public void setMaxMessageSize(int maxMessageSize) {
        this.maxMessageSize = maxMessageSize;
    }

    public int getSendMsgTimeout() {
        return sendMsgTimeout;
    }

    public void setSendMsgTimeout(int sendMsgTimeout) {
        this.sendMsgTimeout = sendMsgTimeout;
    }

    public String getAckMsgTopic() {
        return ackMsgTopic;
    }

    public void setAckMsgTopic(String ackMsgTopic) {
        this.ackMsgTopic = ackMsgTopic;
    }
}
